package com.zyf.chapter02.behavior.observer.eventbus;

import java.util.concurrent.Executor;

/**
 * 非阻塞异步的事件总线
 * @author yifeng
 */
public class AsyncEventBus extends EventBus{
    private Executor executor;
    private ObserverRegistry registry = new ObserverRegistry();

    /**
     * 由调用者注入
     * @param executor 多线程线程池
     */
    public AsyncEventBus(Executor executor) {
        super(executor);
    }
}
